package cn.edu.nchu.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;


public interface MySink {
    // channel 是 topic的抽象,在配置文件中定义与之对应的topic
    String MESSAGE_DOWN = "messages_down";
    String COMMANDS_REQUEST = "commands_request";

    @Input(MESSAGE_DOWN)
    SubscribableChannel message_down();

    @Input(COMMANDS_REQUEST)
    SubscribableChannel commands_request();
}
